#include "groupmodel.hpp"
#include"db.h"
bool GroupModel::createGroup(Group& group)
{
    // 组装sql
    char sql[1024]={0};
    sprintf(sql,"insert into allgroup(groupname,groupdesc) values('%s','%s')",group.getName().c_str(), group.getDesc().c_str());
    MySQL mysql;
    if(mysql.connect())
    {
        if(mysql.update(sql))
        {
            // 这里这个方法要己住
            //  这个代码在 MySQL 数据库的上下文中用于获取最近一次插入操作所生成的自动递增 ID（通常是主键的值）。
            group.setId(mysql_insert_id(mysql.getConn()));
            return true;
        }
    }
    return false;
}
// 加入群组
void GroupModel::addGroup(int userid, int groupid, string role)
{
    // 组装sql
    char sql[1024] ={0};
    sprintf(sql,"insert into groupuser values(%d,%d,'%s')",userid, groupid,role.c_str());
    MySQL mysql;
    if(mysql.connect())
    {
        mysql.update(sql);
    }
}
// 查询用户所在群组 ,有可能不止一个群
vector<Group> GroupModel::queryGroups(int userid)
{
    char sql[1024] ={0};
    sprintf(sql,"select a.id,a.groupname,a.groupdesc from allgroup a inner join groupuser b on a.id=b.groupid where b.userid=%d",userid);
    vector<Group> groups;
    MySQL mysql;
    if(mysql.connect())
    {
        MYSQL_RES* res = mysql.query(sql);
        if(res)
        {
            MYSQL_ROW row;
            // 查出userid群主信息
            while((row=mysql_fetch_row(res))!=nullptr)
            {
                Group group;
                group.setId(atoi(row[0]));
                group.setName(row[1]);
                group.setDesc(row[2]);
                groups.push_back(group);
            }
            mysql_free_result(res);
        }
    }
    // 查询组员信息
    for(Group& group : groups)
    {
        char sql[1024] = {0};
        sprintf(sql,"select a.id,a.name,a.state,b.grouprole from user a inner join groupuser b on a.id=b.userid where b.groupid=%d",group.getId());
        MYSQL_RES* res = mysql.query(sql);
        if(res)
        {
            MYSQL_ROW row;
            // 查出userid群主信息
            while((row=mysql_fetch_row(res))!=nullptr)
            {
                GroupUser user;
                user.setId(atoi(row[0]));
                user.setName(row[1]);
                user.setState(row[2]);
                user.setRole(row[3]);
                group.getUsers().push_back(user);
            }
        }
    }
    return groups;
}
// 根据指定的groupid 查询群主用户id列表，出了userid自己意外，主要用户群聊业务给群组其他人员发送消息
vector<int> GroupModel::queryGroupsUser(int userid, int groupid)
{
    char sql[1024] = {0};
    sprintf(sql,"select userid from groupuser where groupid=%d and userid!=%d",groupid,userid);
    vector<int> userids;
    MySQL mysql;   
    if (mysql.connect())
    {
        MYSQL_RES* res = mysql.query(sql);
        if(res!=nullptr)
        {
            MYSQL_ROW row;
            while((row=mysql_fetch_row(res))!=nullptr)
            {
                userids.push_back(atoi(row[0]));
            }
            mysql_free_result(res);
        }
    }

    return userids;
}